package com.my.rabbitmq.two;

import com.my.utils.RabbitMQUtils;
import com.rabbitmq.client.Channel;

import java.util.Scanner;

/**
 * @author 林允
 * @version 1.0
 * @description: TODO
 * @date 2023/11/25 14:01
 */
// 生产者 发送大量的消息
public class Task01 {

    // 队列名称
    public static final String QUEUE_NAME = "hello";

    public static void main(String[] args) throws Exception {
        // 发送大量的消息
        Channel channel = RabbitMQUtils.getChannel();
        // 创建队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        // 从控制台当中接收消息
        Scanner sc = new Scanner(System.in);
        while (true){
            String message = sc.next();
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
        }
    }

}
